package com.weigee.ktv.m.subscribe;

import android.support.annotation.NonNull;

import io.reactivex.ObservableEmitter;
import io.reactivex.ObservableOnSubscribe;

/**
 * Created by 林德 on 2017/4/4 16:06.
 * <p/>
 */
public class StartMainSubscribe implements ObservableOnSubscribe<Long>
{
    @Override
    public void subscribe(@NonNull ObservableEmitter<Long> e) throws Exception
    {
        e.onNext(3000L);
        e.onComplete();
    }
}
